package com.artlongs.base;

import reactor.core.Environment;
import reactor.core.Reactor;
import reactor.core.spec.Reactors;

/**
 * Reactor 初始化
 */
public class ReactorInitService {

    public static Reactor init() {
        Reactor reactor = Reactors.reactor()
                .env(new Environment())
                .dispatcher(Environment.RING_BUFFER)
                .get();

        return reactor;
    }

}
